RxJava-তে প্রথম প্রোগ্রাম বা "Hello Reactive World" লেখার জন্য আমরা একটি Observable তৈরি করব এবং সেটি থেকে data emit করব। একটি Observer এর মাধ্যমে emitted data consume করব। এর মাধ্যমে RxJava-এর বেসিক ধারণা বোঝা যাবে।
RxJava "Hello Reactive World" উদাহরণ
import io.reactivex.rxjava3.core.Observable;
public class HelloReactiveWorld {
public static void main(String[] args) {
// Step 1: একটি Observable তৈরি করা
Observable<String> observable = Observable.just("Hello", "Reactive", "World");
// Step 2: একটি Observer তৈরি করা এবং Observable-এ subscribe করা
observable.subscribe(
item -> System.out.println("Received: " + item), // onNext: যখন data emit হবে
error -> System.err.println("Error: " + error), // onError: কোনো error হলে
() -> System.out.println("Completed!") // onComplete: সব data emit হলে
);
}
}
প্রোগ্রামের ব্যাখ্যা
- Observable তৈরি করা
Observable.just("Hello", "Reactive", "World")ব্যবহার করে আমরা একটিObservableতৈরি করেছি যা data emit করবে।
- Observer তৈরি এবং Subscribe করা
observable.subscribe()-এর মাধ্যমে আমরা data গ্রহণ করার জন্য একটি Observer তৈরি করেছি।onNext: Data emit হলে এটি কল হয়। এখানে আমরা প্রতিটি data প্রিন্ট করেছি।onError: কোনো error হলে এটি কল হয়।onComplete: সব data emit শেষ হলে এটি কল হয়।
আউটপুট
Received: Hello
Received: Reactive
Received: World
Completed!
এই প্রোগ্রামের বৈশিষ্ট্য
- এটি একটি asynchronous প্রোগ্রাম হলেও খুব সহজে লেখা যায়।
- Reactive Programming-এর মৌলিক ধারণা প্রদর্শন করে।
- Functional programming স্টাইল ব্যবহারের মাধ্যমে কোড পরিষ্কার ও সহজ।
এই ছোট উদাহরণ দিয়ে আপনি RxJava-এর বেসিক ধারণা পেতে পারেন এবং ভবিষ্যতে complex asynchronous operations এর জন্য এটি ব্যবহার করতে পারেন।
Content added By
Read more
